github.com/go-pg/pg/v10.Stmt.db (field)
26 uses
github.com/go-pg/pg/v10 (current package)
stmt.go#L18: db *baseDB
stmt.go#L28: db: db,
stmt.go#L43: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L45: if err := internal.Sleep(ctx, stmt.db.retryBackoff(attempt-1)); err != nil {
stmt.go#L49: err := stmt.db.pool.(*pool.StickyConnPool).Reset(ctx)
stmt.go#L57: stmt.name, stmt.columns, err = stmt.db.prepare(ctx, cn, q)
stmt.go#L60: if !stmt.db.shouldRetry(lastErr) {
stmt.go#L71: err := stmt.db.withConn(c, fn)
stmt.go#L89: ctx, evt, err := stmt.db.beforeQuery(ctx, stmt.db.db, nil, stmt.q, params, nil)
stmt.go#L96: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L98: lastErr = internal.Sleep(ctx, stmt.db.retryBackoff(attempt-1))
stmt.go#L108: if !stmt.db.shouldRetry(lastErr) {
stmt.go#L113: if err := stmt.db.afterQuery(ctx, evt, res, lastErr); err != nil {
stmt.go#L154: ctx, evt, err := stmt.db.beforeQuery(ctx, stmt.db.db, model, stmt.q, params, nil)
stmt.go#L161: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L163: lastErr = internal.Sleep(ctx, stmt.db.retryBackoff(attempt-1))
stmt.go#L173: if !stmt.db.shouldRetry(lastErr) {
stmt.go#L178: if err := stmt.db.afterQuery(ctx, evt, res, lastErr); err != nil {
stmt.go#L221: err := stmt.db.Close()
stmt.go#L232: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L240: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
stmt.go#L259: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L267: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
stmt.go#L280: return stmt.db.closeStmt(c, cn, stmt.name)